Testing-duckplyr_Vs_Polars

library(duckplyr)

## Warning: package 'duckplyr' was built under R version 4.3.2

library(tidyverse)

## Warning: package 'tidyr' was built under R version 4.3.2

## Warning: package 'readr' was built under R version 4.3.2

## Warning: package 'purrr' was built under R version 4.3.2

## Warning: package 'dplyr' was built under R version 4.3.2

library(polars)

## Warning: package 'polars' was built under R version 4.3.2

library(data.table)
library(dtplyr)
library(microbenchmark)

## Warning: package 'microbenchmark' was built under R version 4.3.2

library(conflicted)
conflict_prefer("filter", "duckplyr")

duckplyr::duckplyr_df_from_file("bse_compiled_2023_04_13.csv",table_function = "read_csv_auto")

## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## read_csv_auto(bse_compiled_2023_04_13.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - SC_CODE (BIGINT)
## - SC_NAME (VARCHAR)
## - SC_GROUP (VARCHAR)
## - SC_TYPE (VARCHAR)
## - OPEN (DOUBLE)
## - HIGH (DOUBLE)
## - LOW (DOUBLE)
## - CLOSE (DOUBLE)
## - LAST (DOUBLE)
## - PREVCLOSE (DOUBLE)
## - NO_TRADES (BIGINT)
## - NO_OF_SHRS (BIGINT)
## - NET_TURNOV (BIGINT)
## - TDCLOINDI (VARCHAR)
## - date (DATE)
## - exchange (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Limit 10000
##   r_dataframe_scan(0x25be6369898)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - SC_CODE (DOUBLE)
## - SC_NAME (VARCHAR)
## - SC_GROUP (VARCHAR)
## - SC_TYPE (VARCHAR)
## - OPEN (DOUBLE)
## - HIGH (DOUBLE)
## - LOW (DOUBLE)
## - CLOSE (DOUBLE)
## - LAST (DOUBLE)
## - PREVCLOSE (DOUBLE)
## - NO_TRADES (DOUBLE)
## - NO_OF_SHRS (DOUBLE)
## - NET_TURNOV (DOUBLE)
## - TDCLOINDI (VARCHAR)
## - date (DATE)
## - exchange (VARCHAR)

data.table::fread("bse_compiled_2023_04_13.csv")

perf_7mb__duck <- microbenchmark(
               tidy = readr::read_csv("bse_compiled_2023_04_13.csv"),
               data_table = data.table::fread("bse_compiled_2023_04_13.csv"),
               polars = pl$read_csv("bse_compiled_2023_04_13.csv"),
               polars_df = pl$read_csv("bse_compiled_2023_04_13.csv") |> as.data.frame(),
               duckplyr = duckplyr::duckplyr_df_from_file("bse_compiled_2023_04_13.csv",
                                                          table_function = "read_csv_auto"),
               duckplyr_df = duckplyr::duckplyr_df_from_file("bse_compiled_2023_04_13.csv",
                                                          table_function = "read_csv_auto") |>
                 as.data.frame()
)

perf_7mb__duck

autoplot(perf_7mb__duck)

Read & head()

perf_test_duck_fn <- function(data_file){
  perf_data <<- microbenchmark(
               tidy = readr::read_csv(data_file) %>% head(n=10),
               
               data_table = data.table::fread("bse_compiled_2023_04_13.csv") %>% head(n=10),
               
               duckplyr = duckplyr::duckplyr_df_from_file(data_file,
                                                          table_function = "read_csv_auto") %>%
                 head(n=10),
               
               polars = pl$read_csv(data_file) |> as.data.frame() %>%
               head(n=10),
               
               polars_head = pl$read_csv(data_file)$head(n=10) |>
               as.data.frame(),
               
               polars_lazy_head = pl$scan_csv(data_file)$head(n=10)$collect(),
               
               polars_lazy_head_df = pl$scan_csv(data_file)$head(n=10) |> as.data.frame()
  )
  return( perf_data)
}

perf_test_duck_fn("bse_compiled_2023_04_13.csv")

autoplot(perf_data)

Read only

perf_test_duck_full <- function(data_file){
  perf_data <<- microbenchmark(
               tidy = readr::read_csv(data_file),
               
               data_table = data.table::fread(data_file),
               
               duckplyr = duckplyr::duckplyr_df_from_file(data_file,
                                                          table_function = "read_csv_auto"),
               
               polars = pl$read_csv(data_file),
               
               polars_df = pl$read_csv(data_file) |> as.data.frame(),
               
               polars_lazy_df = pl$scan_csv(data_file)$collect()
  )
  return( perf_data)
}

7mb file

perf_test_duck_full("bse_compiled_2023_04_13.csv")

autoplot(perf_data)

87mb file

perf_test_duck_full("T_ONTIME_REPORTING.csv")

autoplot(perf_data)

Read & Manipulation

duckplyr::duckplyr_df_from_file("T_ONTIME_REPORTING.csv",
                                table_function = "read_csv_auto") %>%
  duckplyr::filter(ORIGIN == "JFK") %>% 
  group_by(ORIGIN_CITY_NAME,DEST_CITY_NAME) %>% 
  summarise(counts = n())

## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)

87mb file

perf_mainpulation <- microbenchmark(
          polars = pl$read_csv("T_ONTIME_REPORTING.csv")$
                    filter(pl$col("ORIGIN") == "JFK")$
                    group_by(c("ORIGIN_CITY_NAME","DEST_CITY_NAME"))$
                    agg(pl$len()$alias("counts")),
          
          polars_df = pl$read_csv("T_ONTIME_REPORTING.csv")$
                    filter(pl$col("ORIGIN") == "JFK")$
                    group_by(c("ORIGIN_CITY_NAME","DEST_CITY_NAME"))$
                    agg(pl$len()$alias("counts")) |> as.data.frame(),
          
          polars_lazy = pl$scan_csv("T_ONTIME_REPORTING.csv")$
                    filter(pl$col("ORIGIN") == "JFK")$
                    group_by(c("ORIGIN_CITY_NAME","DEST_CITY_NAME"))$
                    agg(pl$len()$alias("counts"))$collect(),
          
          polars_lazy_df = pl$read_csv("T_ONTIME_REPORTING.csv")$
                    filter(pl$col("ORIGIN") == "JFK")$
                    group_by(c("ORIGIN_CITY_NAME","DEST_CITY_NAME"))$
                    agg(pl$len()$alias("counts")) |> as.data.frame(),
          
          tidy = read_csv("T_ONTIME_REPORTING.csv") %>% 
                  filter(ORIGIN == "JFK") %>% 
                  group_by(ORIGIN_CITY_NAME,DEST_CITY_NAME) %>% 
                  summarise(counts = n()),
          
          data_table_dtplyr = data.table::fread("T_ONTIME_REPORTING.csv") %>% 
                  filter(ORIGIN == "JFK") %>% 
                  group_by(ORIGIN_CITY_NAME,DEST_CITY_NAME) %>% 
                  summarise(counts = n()),
          
          duckplyr = duckplyr::duckplyr_df_from_file("T_ONTIME_REPORTING.csv",
                                table_function = "read_csv_auto") %>%
                      duckplyr::filter(ORIGIN == "JFK") %>% 
                      group_by(ORIGIN_CITY_NAME,DEST_CITY_NAME) %>% 
                      summarise(counts = n())
)

## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)
## 
## materializing:
## ---------------------
## --- Relation Tree ---
## ---------------------
## Filter [==(ORIGIN, 'JFK')]
##   read_csv_auto(T_ONTIME_REPORTING.csv)
## 
## ---------------------
## -- Result Columns  --
## ---------------------
## - YEAR (BIGINT)
## - QUARTER (BIGINT)
## - MONTH (BIGINT)
## - DAY_OF_MONTH (BIGINT)
## - DAY_OF_WEEK (BIGINT)
## - FL_DATE (TIMESTAMP)
## - OP_UNIQUE_CARRIER (VARCHAR)
## - OP_CARRIER (VARCHAR)
## - TAIL_NUM (VARCHAR)
## - OP_CARRIER_FL_NUM (BIGINT)
## - ORIGIN_AIRPORT_ID (BIGINT)
## - ORIGIN_AIRPORT_SEQ_ID (BIGINT)
## - ORIGIN_CITY_MARKET_ID (BIGINT)
## - ORIGIN (VARCHAR)
## - ORIGIN_CITY_NAME (VARCHAR)
## - ORIGIN_STATE_ABR (VARCHAR)
## - DEST_AIRPORT_ID (BIGINT)
## - DEST_AIRPORT_SEQ_ID (BIGINT)
## - DEST_CITY_MARKET_ID (BIGINT)
## - DEST (VARCHAR)
## - DEST_CITY_NAME (VARCHAR)
## - DEST_STATE_ABR (VARCHAR)
## - CRS_DEP_TIME (VARCHAR)
## - DEP_TIME (VARCHAR)
## - DEP_DELAY (DOUBLE)
## - CRS_ARR_TIME (VARCHAR)
## - ARR_TIME (VARCHAR)
## - CANCELLATION_CODE (VARCHAR)

perf_mainpulation

autoplot(perf_mainpulation)

profvis

library(profvis)

7mb file

profvis({
  duckplyr::duckplyr_df_from_file("bse_compiled_2023_04_13.csv",
                                table_function = "read_csv_auto")
})

an image caption Source: profvis data

87mb file

profvis({
  duckplyr::duckplyr_df_from_file("T_ONTIME_REPORTING.csv",
                                table_function = "read_csv_auto")
})

an image caption Source: profvis data